<?php 

function get_files_dir($dir, $tipos = null){
      if(file_exists($dir)){
          $dh =  opendir($dir);
          while (false !== ($filename = readdir($dh))) {
              if($filename != '.' && $filename != '..'){
                  if(is_array($tipos)){
                      $extensao = get_extensao_file($filename);
                      if(in_array($extensao, $tipos)){
                          $files[] = $filename;
                      }
                  }
                  else{
                      $files[] = $filename;
                  }
              }
          }
          if(is_array($files)){
              sort($files);
          }
          return $files;
      }
      else{
          return false;
      }
}
 

function get_extensao_file($nome){
    $verifica = explode('.', $nome);
    return $verifica[count($verifica) - 1];
}

	$extensoes = array('sql');
	$nomes = get_files_dir('app/database/scripts/mysql', $extensoes);

        $ini = parse_ini_file("app/config/permission.ini");
	
	$host = "mysql:host=".$ini['host'];
	$user = $ini['user'];
	$pass = $ini['pass'];
	$dbn  = ";dbname=".$ini['name'];
	$port = $ini['port'];
	
	if($port != ''){
		$host = $host.":".$port;
	}

 	try{
		$con = new PDO( $host.$dbn, $user, $pass);
		
		if(isset($_GET['zerar'])){                                                
					$stmt = $con->prepare('delete from arquivo_atualizacao'); 				
					$stmt->execute();		        }    

		if(is_array($nomes)){
	         foreach ($nomes as $nome){			$rs = $con->prepare("Select * from arquivo_atualizacao where nome_arquivo = ?");
			
			$rs->bindParam(1,$nome); 
			if($rs->execute()){ 

				if($rs->rowCount() == 0){                                  					$carga_arquivo = Array();

					$carga_arquivo = file('app/database/scripts/mysql/'.$nome);
 		
					$prepara = "";
  		
					foreach($carga_arquivo as $v) $prepara.=$v;
 
					$sql = explode(";",$prepara);
 
					foreach($sql as $v)
					{
						if($v != '')
						{
							$stmt = $con->prepare($v); 
							$stmt->execute();		
					

						}
					}
					$stmt = $con->prepare('insert into arquivo_atualizacao values(?)'); 
					$stmt->bindParam(1,$nome);
					$stmt->execute();		

	         		echo "Arquivo ".$nome." executado com sucesso."."<br />";
                }
			}
		  }	
		}

	}catch(PDOException $e){ 
		echo 'Error: ' . $e->getMessage();
	}

	


?>
